package com.teaphy.coroutinecrawler.flow

import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.runBlocking

fun main() = runBlocking {

    val flow: Flow<Int> = flowOf(1, 2, 3, 4, 5)

    flow.collect {
        println("接收数据: $it")
    }

    print("Done")
}

